package com.awesome.spring.function.source;

import org.apache.flink.api.common.functions.MapFunction;

/**
 * @program: awesome-spring
 * @description: 对流数据进行映射转换，属于 转换（Transformation）操作
 * @author: Alex Wu
 * @createDate: 2025-03-20 15:28
 **/
public class BehaviorLogSourceFunc implements MapFunction<String, String> {
    @Override
    public String map(String source) throws Exception {
        return System.currentTimeMillis() + "-" + source;
    }
}
